package org.hyl.javaext.disruptor.demo1;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ConcurrentLinkedQueue;

public class Main {
	 public static void main(String[] args) {
	        // ��ʼ����������
	        BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(1000);
	        //ConcurrentLinkedQueue<String> blockingQueue = new ConcurrentLinkedQueue<>(1000);
	        // �����������߳�
	        Thread producer = new Thread(new Producer(blockingQueue, "temp.dat"));
	        producer.start();
	        // �����������߳�
	        Thread consumer = new Thread(new Consumer(blockingQueue));
	        consumer.start();
	    }
}
